package com.zjw.demo.vertx.starter.template.subscribe;

import com.zjw.demo.vertx.starter.plugin.impl.event.Consumer;
import com.zjw.demo.vertx.starter.plugin.impl.event.Subscribe;
import com.zjw.demo.vertx.starter.utils.LogUtils;
import io.vertx.core.eventbus.Message;

@Subscribe
public class DemoSubscribe {


  @Consumer(address = "message")
  public void message(Message<String> message) {
    LogUtils.debug("receive message", message.body());
  }
}
